package net.oschina.jms.producer;

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * @Author: AiBinXiao
 * @Description: 启动生产者类
 * @Date: 2017/11/1 15:50
 */

public class AppProducer {

    public static void main(String[] args) {
        // 装载配置文件
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("producer.xml");
        ProducerService service = context.getBean(ProducerService.class);
        // 循环发送100条消息，运行之后可以在ActiveMQ管理页面上查看是否发送成功
        for (int i=0; i<100; i++) {
            service.sendMessage("test" + i);
        }
        context.close();
        // 注意：如果这样关闭的话，会清除我们的连接，因为现在使用的是spring提供的连接，
        // 它会忽略我们连接的close方法，所以会导致应用程序一直在启动状态，
        // 我们加入context.close();后，我们的应用程序关闭后，spring会自动把所有资源清理完
    }
}
